package main

import (
	"fmt"
	"time"

	"gitee.com/chen_wei_jing/kinx/ziface"
	"gitee.com/chen_wei_jing/kinx/zlog"
	"gitee.com/chen_wei_jing/kinx/znet"
)

func main() {
	ch := make(chan int)
	client := znet.NewKcpClient("127.0.0.1", 7777, 30)
	client.StartHeartBeat(2 * time.Second)
	client.SetOnConnStop(func(i ziface.IConnection) {
		fmt.Println("Conn Close:", i.GetConnID())
	})
	// client := znet.NewKcpClient("35.95.34.53", 7777, 30)

	// for range 100 {
	// 	connId, err := client.Connect()
	// 	fmt.Printf("connId:%d err:%s", connId, err)
	// 	time.Sleep(1 * time.Second)
	// }

	// _, err := client.Connect2()
	// if err != nil {
	// 	fmt.Println("连接失败:", err)
	// 	return
	// } else {
	// 	fmt.Println("连接成功!")
	// }

	connId, _ := client.Connect(10)

	if connId <= 0 {
		fmt.Println("连接失败!")
		return
	}

	// for i := 1; i < 1000; i++ {
	// 	time.Sleep(100 * time.Millisecond)
	// 	// client.SendMsg(connId, 66666, []byte("hello heart client test!!!"))

	// 	// fmt.Println("发送测试数据:", i)
	// 	connId, _ := client.Connect(10)

	// 	if connId <= 0 {
	// 		fmt.Println("连接失败!")
	// 		return
	// 	} else {
	// 		fmt.Println("连接成功！connId=", connId)
	// 	}
	// }

	<-ch
	zlog.Ins().DebugF("client exit!")
}
